// 默认我们使用 fs.createReadStream  以及 fs.createWriteStream 
// 都是基于文件模块的  

// http 请求，客户端请求服务端的时候，会将发布的内容全部放到可独流中
import { Writable } from 'stream';

class MyWriteStream extends Writable {
    // 父类的write 会调用子类的_write (一种是放到缓存中了，一种调用的是 _write)
    _write(chunk, encoding, clearBuffer) {

        // fs.write
        console.log(chunk)
        clearBuffer()
    }
}

const mws = new MyWriteStream();


mws.write('abc')
mws.write('bcd'); // 放入到缓存中
mws.write('bcd');
mws.end('ok')